package com.example.eureka.client.eurekaclient.rabbitMq;

import com.rabbitmq.client.*;

import java.io.IOException;
import java.nio.channels.Channel;
import java.sql.Connection;
import java.util.concurrent.TimeoutException;
import java.util.function.Consumer;

public class Customer {
    private static final String QUEUE_NAME = "rabbitMQ.test";

//    public static void main(String[] args) throws IOException, TimeoutException {
//        ConnectionFactory factory = new ConnectionFactory();
//        factory.setHost("localhost");
//        Connection connection = factory.newConnection();
//        Channel channel = connection.createChannel();
//        channel.queueDeclare(QUEUE_NAME,false,false,true,null);
//        System.out.println("coustomer waiting received messge ..........");
//
//        Consumer consumer = new DefaultConsumer(channel){
//            @Override
//            public void handleDelivery(String tag ,Envelope envelope,AMQP.BasicProperties properties,byte[] body)throws IOException{
//                String message = new String(body,"UTF-8");
//                System.out.println("customer received "+message);
//            }
//        };
//        channel.basicConsume(QUEUE_NAME,true,consumer);
//    }

}
